c27d5ec756b5bc9c42e4b4185b6fb1c38c3273a5,opennms-services/src/main/java/org/opennms/netmgt/eventd/EventIpcManagerDefaultImpl.java,EventIpcManagerDefaultImpl,broadcastNow,#Event#,280
Before Change
* Called by eventd to send an event to all interested listeners
*/
public synchronized void broadcastNow(Event event) {
Category log = ThreadCategory.getInstance(this.getClass());
if (log.isDebugEnabled())
log.debug("Event to be broadcasted: " + event.getUei());
if (m_listeners.size() <= 0) {
if (log.isDebugEnabled())
log.debug("No listeners interested in all events");
}
// send to listeners interested in receiving all events
for(EventListener listener : m_listeners) {
ListenerThread listenerThr = m_listenerThreads.get(listener.getName());
try {
listenerThr.getQueue().add(event);
if (log.isDebugEnabled())
log.debug("Queued event to listener: " + listener.getName());
} catch (FifoQueueException fe) {
log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
} catch (InterruptedException ie) {
log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
}
}
// get event UEI
String uei = event.getUei();
if (uei == null) {
return;
}
// send to listeners who are interested in this event uei
//Loop to get partial wild card "directory" matches
while (uei.length() > 0){
List<EventListener> listenerList = m_ueiListeners.get(uei);
if (listenerList != null) {
for(EventListener listener : listenerList) {
ListenerThread listenerThread = m_listenerThreads.get(listener.getName());
try {
listenerThread.getQueue().add(event);
if (log.isDebugEnabled())
log.debug("Queued event "+uei+" to listener: " + listener.getName());
} catch (FifoQueueException fe) {
log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
} catch (InterruptedException ie) {
log.error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
}
}
} else {
if (log.isDebugEnabled())
log.debug("No listener interested in event: " + uei);
}
//Try wild cards: Find / before last character
int i = uei.lastIndexOf("/",uei.length()-2);
After Change
* Called by eventd to send an event to all interested listeners
*/
public synchronized void broadcastNow(Event event) {
if (log().isDebugEnabled()) {
log().debug("Event to be broadcasted: " + event.getUei());
}
if (m_listeners.size() <= 0) {
if (log().isDebugEnabled()) {
log().debug("No listeners interested in all events");
}
}
// send to listeners interested in receiving all events
for (EventListener listener : m_listeners) {
ListenerThread listenerThr = m_listenerThreads.get(listener.getName());
try {
listenerThr.getQueue().add(event);
if (log().isDebugEnabled()) {
log().debug("Queued event to listener: " + listener.getName());
}
} catch (FifoQueueException fe) {
log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
} catch (InterruptedException ie) {
log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
}
}
// get event UEI
String uei = event.getUei();
if (uei == null) {
return;
}
// send to listeners who are interested in this event uei
//Loop to get partial wild card "directory" matches
while (uei.length() > 0) {
List<EventListener> listenerList = m_ueiListeners.get(uei);
if (listenerList != null) {
for (EventListener listener : listenerList) {
ListenerThread listenerThread = m_listenerThreads.get(listener.getName());
try {
listenerThread.getQueue().add(event);
if (log().isDebugEnabled()) {
log().debug("Queued event "+uei+" to listener: " + listener.getName());
}
} catch (FifoQueueException fe) {
log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), fe);
} catch (InterruptedException ie) {
log().error("Error queueing event " + event.getUei() + " to listener thread " + listener.getName(), ie);
}
}
} else {
if (log().isDebugEnabled()) {
log().debug("No listener interested in event: " + uei);
}
}